package repo

import (
	"mine-info-server/domain/common-context/model/message-aggregate/aggregate"
	"mine-info-server/interfaces/response"
)

/*
   @author:zhongyang
   @date:2023/4/12
   @description:消息-仓储层接口定义
*/

type MsgIRepo interface {
	FindMsgById(msgId string) (*aggregate.MessageAggregate, error)
	ReadMsg(msg *aggregate.MessageAggregate) error
	IsMsgAllRead(userID string) (bool, error)
	GetMsgPageByUserId(page int, userId string, pageSize int, isRead int) ([]*response.MsgItemResponse, int64, error)
}
